package com.wangke.controller;

import com.wangke.util.KafkaSender;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author wangke
 * @version v1.0
 * @项目名称: study
 * @描述:
 * @创建时间: 2019/4/22
 * @update [序号][日期YYYY-MM-DD] [更改人姓名][变更描述]
 */
@RestController
@Slf4j
public class ProducerController {
    @Autowired
    private KafkaSender kafkaSender;

    @RequestMapping("sendMsg")
    public void test(){
        kafkaSender.send();
    }


}
